<?php
namespace web\controller\Index;
use web\controller\BaseController;

use config\KafkaConfig;
class KafkaController extends BaseController{

    public function send(){
        ini_set("display_errors",1);
        $data = array(
            "type" => "test",
            "name" => "miao",
        );
        $rs = sendKafkaMsg(KafkaConfig::TEST_TOPIC,$data);
        echo jsonOut($rs);
    }
}